category: sub_main
step: 2_staging
sub_step: 1_join
in_main_macro: join
doc_status: readymacro join_appmetrica_registry_appprofilematching
| Name | Category | In Sub-Main Macro | Doc Status |
|---|---|---|---|
| get_relations_by_re | auxiliary | join_appmetrica_events, join_appmetrica_registry_appprofilematching, join_appsflyer_events, join_mt_datestat, join_sheets_periodstat, join_vkads_datestat, join_utmcraft_registry_utmhashregistry, join_yd_datestat, join_yd_datestat_smart, join_ym_events | ready |
Этот подвид макроса join предназначен для работы с данными источника appmetrica, которые относятся к пайплайну registry (стрим profiles).
Этот макрос принимает следующие аргументы:
sourcetype_name,
pipeline_name,
relations_dict,
date_from,
date_to,
params,
limit0=none
```
## Функциональность
Макрос обрабатывает данные стрима `profiles` из источника `appmetrica`. Данные о профилях относятся к общей справочной информации - то есть к пайплайну `registry`.
Для вышеуказанного стрима макрос ищет `relations` при помощи вспомогательного макроса [[get_relations_by_re]], затем создаёт таблицу-источник при помощи вспомогательного макроса `dbt_utils.union_relations`. (Этот макрос из пакета dbt_utils, он не относится к datacraft).
Далее полученные данные макрос обрабатывает (происходит переименование полей, для некоторых столбцов вводится LowCardinality).
Для этой таблицы задаётся её линк (это будет использоваться на будущих шагах):
- `toLowCardinality('AppProfileMatching') AS __link`
Если аргумент `limit0` активирован, то в конце SQL-запроса будет добавлено `LIMIT 0`.
## Пример
Файл в формате sql в папке models. Название файла `join_appmetrica_registry_appprofilematching`
Содержимое файла:
```sql
-- depends_on: {{ ref('incremental_appmetrica_registry_default_profiles') }}
{{ datacraft.join(disable_incremental=True) }}